package com.apps.sdses.flink141.demo;

import com.apps.sdses.flink141.entity.Event;
import org.apache.flink.connector.kafka.source.KafkaSource;
import org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer;
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment;

/**
 * @author jiwei
 * @description
 * @date 2023/9/7 18:29
 */
public class ObjectTransformDemo {
    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        KafkaSource<Event> kafkaSource = KafkaSource.<Event>builder()
                .setTopics("ods_water_sensor")
                .setGroupId("test_object_transform")
                .setStartingOffsets(OffsetsInitializer.latest())
//                .setDeserializer()
                .build();

    }
}
